package com.test;

import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableReducer;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

/**
 * @Date 22.6.10
 * @Created by HANGGE
 * @Description
 */
public class IOTest02 {

      public  static   class MyMapper extends Mapper<Text , LongWritable , Text , Text>{

      }

      public  static  class  MyReducer extends TableReducer<Text , Text  , ImmutableBytesWritable>{
          @Override
          protected void reduce(Text key, Iterable<Text> values, Context context) throws IOException, InterruptedException {

              Put put = new Put("".getBytes());
              context.write(null , put);
          }
      }



}
